package com.shanks.framework.mq.repository;

import com.shanks.framework.mq.model.MessageConsumeExceptionRecordPO;

public interface MessageConsumeExceptionRecordRepository {
    void insertExceptionRecord(MessageConsumeExceptionRecordPO messageConsumeExceptionRecordPO);
    /**
     * 删除消费异常记录
     * @param topic
     * @param tags
     * @param key
     */
    void deleteExceptionRecordByMsgTopicTagKey(String topic, String tags, String key);
}
